
package com.sailing.lianxi.thread;

import java.util.concurrent.CountDownLatch;

/**
 * 
 * 类名称：TheadSecurty
 * 类描述：线程安全
 * 创建人：wanggang
 * 创建时间：2018年7月12日 下午4:04:45
 * 修改人：wanggang
 * 修改时间：2018年7月12日 下午4:04:45
 * 修改备注：
 */
public class TheadSecurty {

    public  void  t1(){
        final CountDownLatch countDownLatch = new CountDownLatch(5);
        for(int i=0;i<5;i++){
            new Thread(new Runnable() {
                @Override
                public void run() {
                    int i=0;
                    try {
                    while(true){
                 
                          i+=1;
                          System.out.println("111111="+Thread.currentThread().getName());
                          insertData(i);
//                          if(i==1000){
//                              break;
//                          }
                        
                     }
                    } catch (Exception e) {
                    
                    }finally{
                        countDownLatch.countDown(); 
                    }
                }
            }).start();
            try {
                countDownLatch.await();
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
                
            }
            System.out.println("finish");
        }
    }
    
    public  void insertData(int i){
        ProcessData t1 = new ProcessData();
        String fileName = String.valueOf(i);
        t1.run(fileName);
    }
    
    public static void main(String[] args) {
        new TheadSecurty().t1();
    }
    
   
}

